// const mysql = require('mysql')

// // 创建连接
// const db = mysql.createConnection({
//   host: 'localhost',
//   user: 'root',
//   password: '123456',
//   database: 'mydb'
// })


// // 连接数据库
// db.connect(err => {
//   if (err)  throw err
//   console.log('数据库连接成功！')
// })

// module.exports = db

var mysql = require('mysql')

var mysql_config = {

  host: 'localhost',

  user: 'admin',

  password: '123456',

  database: 'aaa'

}




function sqlConnect(sql, callBack) {
  var pool = mysql.createPool(mysql_config);
  pool.getConnection((err, conn) => {
    console.log("mysql连接成功");
    if (err) {
      console.log('连接失败')
      return
    }
    conn.query(sql, callBack)
    // 释放
    conn.release()
  })
}

// function sqlConnect2(sql, data, callBack) {
//   var pool = mysql.createPool(mysql_config);
//   pool.getConnection((err, conn) => {
//     console.log("mysql连接成功");
//     if (err) {
//       console.log('连接失败')
//       return
//     }
//     var data = {}
//     conn.query(sql, data, callBack)
//     // 释放
//     conn.release()
//   })
// }

module.exports = {
  sqlConnect
}


// function handleDisconnection() {

//   var dbServer = mysql.createConnection(mysql_config)

//   dbServer.connect(function (err) {
//     console.log('数据库链接成功')
//     if (err) {

//       setTimeout(handleDisconnection, 2000)

//     }

//   })

//   dbServer.on('error', function (err) {

//     console.log('db error', err)

//     if (err.code === 'PROTOCOL_CONNECTION_LOST') {

//       console.log('db error执行重连:' + err.message)

//       handleDisconnection()

//     } else {

//       throw err

//     }

//   })

//   return dbServer //返回一个connection对象，用于调用它的其他方法

//   exports.dbServer = dbServer

// }

// exports.handleDisconnection = handleDisconnection